7a617c443bcd82ef06dde80e1218e3f63b716c21,sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/jdbc/adapter/AbstractConnectionAdapter.java,AbstractConnectionAdapter,close,#,78

Before Change


    
    @Override
    public void close() throws SQLException {
        for (Connection each : getConnections()) {
            each.close();
        }
        closed = true;

After Change


    
    @Override
    public void close() throws SQLException {
        SQLUtil.safeInvoke(getConnections(), new ThrowableSQLExceptionMethod<Connection>() {
            @Override
            public void apply(final Connection object) throws SQLException {
                object.close();